privateGPT MCP Server

const net = require('net'); const readline = require('readline'); const { argv, exit } = require('process'); // Funktion zum Parsen der Kommandozeilenargumente function parseArguments(args) { const parsedArgs = {}; for (let i = 2; i < args.length; i++) { switch (args[i]) { case '--server-ip': parsedArgs.serverIp = args[++i]; break; case '--server-port': parsedArgs.serverPort = parseInt(args[++i], 10); break; case '--token': parsedArgs.token = args[++i]; break; case '--source-id': parsedArgs.sourceId = args[++i]; break; case '--title': parsedArgs.title = args[++i]; break; case '--content': parsedArgs.content = args[++i]; break; case '--groups': // Sammle alle Gruppenargumente bis zum nΓ€chsten Flag oder Ende parsedArgs.groups = []; while (i + 1 < args.length && !args[i + 1].startsWith('--')) { parsedArgs.groups.push(args[++i]); } break; default: console.warn(`⚠️ Unbekanntes Argument: ${args[i]}`); } } return parsedArgs; } // Funktion zum interaktiven Abfragen eines Parameters (optional) function askQuestion(query) { const rl = readline.createInterface({ input: process.stdin, output: process.stdout, terminal: true }); return new Promise((resolve) => { rl.question(query, (answer) => { rl.close(); resolve(answer); }); }); } // Funktion zum Senden einer Edit-Source-Anfrage ΓΌber eine TCP-Verbindung function sendEditSourceRequest(serverIp, serverPort, payload) { return new Promise((resolve, reject) => { const client = new net.Socket(); let responseData = ''; client.connect(serverPort, serverIp, () => { console.log(`πŸ”— Verbindung zum Server (${serverIp}:${serverPort}) hergestellt.`); const payloadString = JSON.stringify(payload); console.log(`πŸ“€ Sende Payload: ${payloadString}`); client.write(payloadString); }); client.on('data', (data) => { console.log(`πŸ“₯ Empfangene Daten: ${data}`); responseData += data.toString(); try { const parsedData = JSON.parse(responseData); console.log('βœ… JSON-Antwort erfolgreich geparst.'); resolve(parsedData); client.destroy(); // Verbindung schließen } catch (err) { console.warn('⚠️ Antwort noch nicht vollstΓ€ndig oder ungΓΌltiges JSON. Weitere Daten werden erwartet.'); // Antwort noch nicht vollstΓ€ndig, weiter empfangen } }); client.on('close', () => { console.log('πŸ”’ Verbindung zum Server geschlossen.'); }); client.on('error', (err) => { console.error('❌ Verbindungsfehler:', err.message); reject(err); }); }); } // Hauptfunktion async function main() { const args = argv; const parsedArgs = parseArguments(args); let { serverIp, serverPort, token, sourceId, title, content, groups } = parsedArgs; // ÜberprΓΌfen, ob alle erforderlichen Parameter vorhanden sind, sonst interaktiv abfragen if (!serverIp) { serverIp = await askQuestion('πŸ”— Bitte gib die Server-IP ein: '); } if (!serverPort) { const portInput = await askQuestion('πŸ”— Bitte gib den Server-Port ein: '); serverPort = parseInt(portInput, 10); } if (!token) { token = await askQuestion('πŸ”’ Bitte gib dein Authentifizierungstoken ein: '); } if (!sourceId) { sourceId = await askQuestion('πŸ“ Bitte gib die Source-ID ein: '); } // ÜberprΓΌfen, ob mindestens eines der optionalen Parameter vorhanden ist if (title === undefined && content === undefined && (groups === undefined || groups.length === 0)) { console.warn('⚠️ Keine Γ„nderungsparameter angegeben. Es werden mindestens eines der folgenden benΓΆtigt: --title, --content, --groups.'); exit(1); } // Optional: Abfrage fehlender optionaler Parameter, wenn entsprechende Flags gesetzt sind // Hier gehen wir davon aus, dass --title, --content und --groups bereits korrekt geparst wurden // und entweder definiert sind oder nicht angegeben wurden. // Entferne unerwΓΌnschte SchlΓΌssel mit undefined oder null Werten const filteredArguments = {}; if (sourceId) filteredArguments.sourceId = sourceId; if (title) filteredArguments.title = title; if (content) filteredArguments.content = content; if (groups && groups.length > 0) filteredArguments.groups = groups; const payload = { command: "edit_source", token: token, arguments: filteredArguments }; try { console.log('πŸ› οΈ Sende Edit-Source-Anfrage...'); const response = await sendEditSourceRequest(serverIp, serverPort, payload); console.log('βœ… Server Response:'); console.log(JSON.stringify(response, null, 2)); } catch (err) { console.error('❌ ERROR:', err.message); } } main();